Arrow Resilience Kit/[root]/SlidingWindowCircuitBreaker

SlidingWindowCircuitBreaker

JS/TS-friendly facade over com.sorinirmies.arrow.resiliencekit.SlidingWindowCircuitBreaker.

import { SlidingWindowCircuitBreaker } from "arrow-resilience-kit";

const cb = await SlidingWindowCircuitBreaker.create({ slidingWindowSize: 20, failureRateThreshold: 0.5 });
const result = await cb.execute(() => externalService.call());

Types

Companion

object Companion

Functions

currentState

fun currentState(): Promise<String>

Current state: "Closed", "Open", or "HalfOpen".

execute

fun <T> execute(block: () -> Promise<T>): Promise<T>

Executes block through the circuit breaker. Rejects with an error if the circuit is open.

executeOrFallback

fun <T> executeOrFallback(fallback: () -> Promise<T>, block: () -> Promise<T>): Promise<T>

Executes block, falling back to fallback if the circuit is open.

onStateChange

fun onStateChange(listener: (oldState: String, newState: String) -> Unit)

Registers listener to be called (with the old and new state names) on every state change.

reset

fun reset(): Promise<Unit>

Manually resets the circuit breaker to closed state and clears its window.

statistics

fun statistics(): Promise<SlidingWindowCircuitBreakerStatistics>

Current window statistics snapshot.